package com.bw.been;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

@NoArgsConstructor
@AllArgsConstructor
@ToString
@Data
public class TableProcess {
    //常量
    public static final String SINK_TYPE_HBASE="hbase";
    public static final String SINK_TYPE_KAFKA = "kafka";
    public static final String SINK_TYPE_CK = "clickhouse";

    String sourceTable; //来源表
    String operateType; //操作类型 insert，update
    String sinkType;//输出类型 hbase,kafka
    String sinkTable;//输出表
    String sinkColumns;//输出字段
    String sinkPk;//主键字段
    String sinkExtend;//建表拓展
}
